package com.wang.service;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.otter.canal.protocol.Message;

import java.util.List;

public interface ICanalService {


    /**
     * 获取多少个数据
     * @param batchSize
     * @return
     */
    Message getMessageData(int batchSize);

    /**
     * 获取变更的对象 jsonobject
     * @param batchSize
     * @return
     */
    List<JSONObject> getChangeDataList(int batchSize);

    /**
     * 测试canal任务
     * @param batchSize
     */
    void testData(int batchSize);
}
